d65223002c9f951623dd6b24494408a1f2026824,src/main/java/com/continuuity/fabric/engine/memory/MemoryQueue.java,MemoryQueue,pop,#QueueConsumer#QueuePartitioner#,48
Before Change
throws InterruptedException {
// Anything in the queue at all? Wait for a push if so
if (head == null) {
waitForPush();
return pop(consumer, partitioner);
}
After Change
throws InterruptedException {
// Anything in the queue at all? Wait for a push if so
if (head == null) {
if (sync) waitForPush(); else return null;
return pop(consumer, partitioner);
}